#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2024/6/5 12:26
# @Author : 闫峰
# @File    : testallegroListingTemplateHandler.py
from apps.zhcxkj_center_data.prod.views.get_active_source_id import Common
from testcases.java_Intelligent_publishing.allegro.prod.listing_filter_model_prod import ListingFilterModel


from utils.otherutils.MyThreadPool import MyThreadPool


class TestAllegroListingTemplateHandler:

    def test_main(self, listingTemplateId):
        """
        Allegro-listing分级模版 调度任务
        :param listingTemplateId:
        :return:
        """
        # 创建一个分级模版 这个分级模版要保证各个条件都参与了过滤
        # 执行java 调度任务
        # 等待
        # 查询有效的渠道source_id_list
        source_id_list = Common.get_active_source_id_list(67)
        # 初始化调度任务执行器
        ListingFilterModelExe = ListingFilterModel(listingTemplateId)
        # task_list = [9046, 9058, 9059, 9062]
        # 分渠道分发 多线程执行 执行结果记录到 执行结果表
        task_list = [9046, 9058]
        task_list = [9046]
        """
        2020-11-13 02:25:13  2024-03-12 11:53:55
        5.62  399.99  
        价格过滤 13336260052
        类目过滤 13307926443
        sku = 7513922  库存=4
        """
        MyThreadPool(10).multithreaded(ListingFilterModelExe.sku_filter, task_list)
        # 钉钉发送 执行失败标红显示
        # 删除 执行结果表


if __name__ == '__main__':
    TestAllegroListingTemplateHandler().test_main(52)
    # ListingFilterModel(51).sku_filter(9046)
